package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.JxcBinderConstant;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Service;

/**
 * jxc 消息队列
 * @author 魏荣杰
 * @date 2019/2/22 18:51
 * @since v1.0
 * @version v1.0
 */
@Service("jxcProducerBinder")
public interface JxcProducerBinder {
    /**
     * 供应商
     */
//    @Input(JxcBinderConstant.SUPPLIER_INPUT)
//    SubscribableChannel supplierInput();
    @Output(JxcBinderConstant.SUPPLIER_OUTPUT)
    MessageChannel supplierOutput();

    /**
     * 采购合同
     */
//    @Input(JxcBinderConstant.PURCHASE_INPUT)
//    SubscribableChannel purchaseInput();
    @Output(JxcBinderConstant.PURCHASE_OUTPUT)
    MessageChannel purchaseOutput();

    /**
     * 出库单
     */
//    @Input(JxcBinderConstant.OUTSTOCK_INPUT)
//    SubscribableChannel outstockInput();
    @Output(JxcBinderConstant.OUTSTOCK_OUTPUT)
    MessageChannel outstockOutput();

    /**
     * 入库单
     */
//    @Input(JxcBinderConstant.INSTOCK_INPUT)
//    SubscribableChannel instockInput();
    @Output(JxcBinderConstant.INSTOCK_OUTPUT)
    MessageChannel instockOutput();

    /**
     * bom
     */
//    @Input(JxcBinderConstant.BOM_INPUT)
//    SubscribableChannel bomInput();
    @Output(JxcBinderConstant.BOM_OUTPUT)
    MessageChannel bomOutput();

    /**
     * 生产单
     */
//    @Input(JxcBinderConstant.PRODUCTION_ORDER_INPUT)
//    SubscribableChannel productionOrderInput();
    @Output(JxcBinderConstant.PRODUCTION_ORDER_OUTPUT)
    MessageChannel productionOrderOutput();
}
